//package hadoop_2;
//
//import java.io.InputStream;
//import java.net.URI;
//import org.apache.hadoop.conf.Configuration;
//import org.apache.hadoop.fs.FileSystem;
//import org.apache.hadoop.fs.Path;
//import org.apache.hadoop.io.IOUtils;
////用输出流FSDataOutputStream给HDFS的hello.txt文件中写入文字(文件不存在会自动创建)
//public class Test1 {
//
//	public static void readFile()throws  Exception {
//        Configuration  conf=new Configuration();
//        //1.配置类(hadoop配置文件作用，把配置文件的信息读出来赋值给conf对象)
//
//        String uri="hdfs://master:9000/hdfs/hello.txt";
//        FileSystem fs=FileSystem.get(URI.create(uri),conf);
//        //2.文件系统(HDFS分布式文件系统，给HDFS保存，HDFS删除文件，HDFS移动文件，HDFS下载文件)
//
//        InputStream in=fs.open(new Path(uri));
//        //3. 数据输出流对象(作用：将电脑内存中的"hello yanzhi"输出写出到HDFS文件系统的hello.txt)
//
//        IOUtils.copyBytes(in, System.out, 4096,false);
//        IOUtils.closeStream(in);
//    }
//
//
//	public static void main(String[] args) throws Exception {
//		readFile();
////		Configuration  conf=new Configuration();  //1.//alt  ?
////		conf.set("fs.defaultFS", "hdfs://master:9000");//HDFS的地址
////		conf.set("fs.hdfs.impl", "org.apache.hadoop.hdfs.DistributedFileSystem");//给配置类设置一个DistributedFileSystem
////
////		String dst="hdfs://master:9000/hdfs/hello.txt";
////		FileSystem  fs=FileSystem.get(URI.create(dst),conf);//2.
////
////		FSDataOutputStream out=fs.create(new Path(dst));//3.
////
////		String str="共产主义好，共产主义妙";
////		out.write(str.getBytes()  ,  0,   str.getBytes().length );//4.用输出流的write()将字节数组数据写出去
////		out.close();
////		System.out.println("写入成功");
//	}
//
//}//9:22上课
//
//
//
//
//
//
